package com.tjf.myjetpackdemo.RxObserverModel;


/**
 * @author: tjf
 * @date: 2023-06-07
 * @desc： 抽象的观察者
 */
public abstract class BaiseFuseableOberver<T, R> implements Observer<T> {

    protected final Observer<R> actual;

    public BaiseFuseableOberver(Observer<R> actual) {
        this.actual = actual;
    }

    @Override
    public void onSubscribe() {
        actual.onSubscribe();
    }


    public void onError(Throwable throwable) {
        actual.onError(throwable);
    }

    @Override
    public void onComplete() {
        actual.onComplete();
    }
}
